//链接数据库
const mysql = require('mysql');
//导入数据库配置信息
const dbcfg = require('./dbcfg');

let con;

function query(sql,params){
    return new Promise(async (resolve,reject)=>{
        //等待数据库链接成功
        await connect();
        con.query(sql,params,(e,r)=>{
            if(e){
                console.log("数据错误",e);
            }else{
                //数据正常
                resolve(r);
            }
            con.end(e=>{
                console.log("数据库关闭成功！");
            });
        })
    
    })
}

//链接数据库
function connect(){
    // 创建新链接
    con = mysql.createConnection(dbcfg);
    return new Promise((resolve,reject)=>{
        con.connect(e=>{
            if(e){
                console.log("数据库链接错误:",e);
            }else{
                console.log("链接成功！");
                resolve();
            }
        })
    })
}

module.exports.query = query;